package com.doubao.common.mq.producer;

import java.util.Map;

/**
 * 消息生产者接口
 */
public interface MessageProducer {

    /**
     * 发送消息
     * @param topic 主题
     * @param message 消息内容
     */
    void sendMessage(String topic, Object message);

    /**
     * 发送带标签的消息
     * @param topic 主题
     * @param tags 标签
     * @param message 消息内容
     */
    void sendMessage(String topic, String tags, Object message);

    /**
     * 发送延迟消息
     * @param topic 主题
     * @param message 消息内容
     * @param delayLevel 延迟级别
     */
    void sendDelayedMessage(String topic, Object message, int delayLevel);
}